package com.gph.saviorframework.mq.api.transaction;

import com.gph.saviorframework.mq.api.Message;

/**
 * 回查本地事务，由Broker回调Producer
 */
public interface LocalTransactionChecker {

    /**
     * 回查本地事务，Broker回调Producer，将未结束的事务发给Producer，由Producer来再次决定事务是提交还是回滚
     *
     * @param msg
     *         消息
     *
     * @return 事务状态
     */
    public TransactionStatus check(final Message msg);
}